package com.api

import scala.actors.Actor

/**
 * 通信模型，Spark底层代码就是scala,spark 底层节点之间的通信就是使用Akka,Akka的底层实现就是Actor实现的。
 * Actor相当于我们理解的线程,Thread。
 */
class MyActor extends Actor{
  def main(args: Array[String]): Unit = {

  }

  override def act(): Unit = {
    receive{
      case s:String=>println("value is "+s)
    }
  }
}
object Lesson_Actor{
  def main(args: Array[String]): Unit = {
    val actor=new MyActor()
    actor.start();
    actor ! "hello"
  }
}